import zerorpc


class HelloRPC(object):
    def hello(self, name):
        return "Hello,%s" % name

    @zerorpc.stream
    def streaming_range(self, fr, to, step):
        """
        流式响应
        @zerorpc.stream这里的函数修饰是必须的，
        否则会有异常，如TypeError: can’t serialize
        """
        return range(fr, to, step)


s = zerorpc.Server(HelloRPC())
s.bind("tcp://0.0.0.0:4242")
s.run()
